package com.lanp.springredis.controller;

import com.lanp.springredis.config.RedisCmt;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
//
//@RestController
//@RequestMapping("test")
public class TestRest {
    @Autowired
    private RedisCmt redisCmt;

    /**
     * 单机/多机调用不同db库
     *
     * @param a
     * @return
     */
    @GetMapping("/a")
    public Object testa(String a) {
        if ("a".equals(a)) {
            return redisCmt.dbForProduct().opsForValue().get(a);
        } else {
            return redisCmt.dbForCategory().opsForValue().get(a);
        }
    }

    /**
     * 集群调用
     *
     * @param key
     * @return
     */
    @GetMapping("/bget")
    public Object testb(String key) {
        return redisCmt.dbForProduct().opsForValue().get(key);
    }

    /**
     * 集群调用
     *
     * @param key
     * @return
     */
    @GetMapping("/bset")
    public Object testbset(String key, String val) {
        redisCmt.dbForProduct().opsForValue().set(key, val);
        return "设置成功";
    }
}
